#if !defined(__APP_MQTT)
#define __APP_MQTT

#define ADDRESS     "tcp://192.168.31.10:1883"
#define CLIENTID    "f9daa00d-3b84-4768-a714-1819a3df0c04"
#define TOPIC_PUSH       "push"
#define TOPIC_PULL      "pull"
#define QOS         1
#define TIMEOUT     10000L

/**
 * @brief 初始化MQTT客户端
 */
int app_mqtt_init();

/**
 * 关闭MQTT客户端
 */
void app_mqtt_close();

/**
 * 发送消息
 */
int app_mqtt_sendMsg(char *data, int len);

/**
 * 设置用于接收消息的回调函数
 */
void app_mqtt_setRecvCallback(int (*callback)(char *, int));

#endif // __APP_MQTT
